package com.car.main;

import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import com.bbs.crawl.ReplyCarwlBitAuto;
import com.bbs.dao.ReplyDaoOfBitAuto;

public class ReplyMainOfBitAuto {
	public static void main(String[] args) {
		ReplyDaoOfBitAuto replyDaoOfBitAuto = new ReplyDaoOfBitAuto();
		ExecutorService fixedThreadPool = Executors.newFixedThreadPool(35);
		List<Integer> uid = replyDaoOfBitAuto.getUserID();
		System.out.println(uid.size());
		for (Integer userid : uid) {
			fixedThreadPool.execute(new ReplyCarwlBitAuto(replyDaoOfBitAuto, userid));
		}
		fixedThreadPool.shutdown();
	}
}
